package com.henry.consumer;

import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;

/**
 * RocketConsumer 顶层接口
 *
 * @author Liu Hanlin
 * @create 2025-11-10 23:49
 */
public interface Consumer {

    /**
     * 获取消费者订阅的topic
     *
     * @return
     */
    String getTopic ();

    /**
     * 获取消费者订阅的tag
     *
     * @return
     */
    String getTag ();

    /**
     * 消费者模式
     *
     * @return
     */
     MessageModel getConsumerMode ();
}
